#数据库操作

library(RMySQL)

#查询航班数据
findFlights <- function(){
  #连接数据库
  #user:数据库用户名，password:数据库密码,
  #host数据库服务器地址（127.0.0.1是指本地数据库）
  #dbname数据库名
  con <- dbConnect(MySQL(), 
                   user='root',
                   password='root',
                   port=3307,
                   host='127.0.0.1',
                   dbname='flightinfo')
  
  flightsdata <- dbGetQuery(con, "select year,month,day,
                      dep_delay,arr_delay,
                            distance,dest
                            from flights")
  
  #关闭数据库连接
  dbDisconnect(con)
  
  return (flightsdata)
}






